Class Handle

Shared base of Consumer and Producer.

Inheritance
System.Object
Handle
Namespace:RdKafka
Assembly:cs.temp.dll.dll
Syntax
public class Handle : IDisposable

Properties

LogLevel

Declaration
public int LogLevel { set; }
Returns
Type Description
System.Int32

MemberId

The client's broker-assigned group member id

Last assigned member id, or empty string if not currently a group member.

Declaration
public string MemberId { get; }
Returns
Type Description
System.String

Name

The name of the handle

Declaration
public string Name { get; }
Returns
Type Description
System.String

OutQueueLength

The current out queue length

The out queue contains messages and requests waiting to be sent to, or acknowledged by, the broker.

Declaration
public long OutQueueLength { get; }
Returns
Type Description
System.Int64

Methods

Dispose()

Declaration
public virtual void Dispose()

ListGroup(String, TimeSpan)

Declaration
public Task<GroupInfo> ListGroup(string group, TimeSpan timeout)
Parameters
Type Name Description
System.String group
System.TimeSpan timeout
Returns
Type Description
Task<GroupInfo>

ListGroups(TimeSpan)

Declaration
public Task<List<GroupInfo>> ListGroups(TimeSpan timeout)
Parameters
Type Name Description
System.TimeSpan timeout
Returns
Type Description
Task<System.Collections.Generic.List<GroupInfo>>

Metadata(Boolean, Topic, Boolean, TimeSpan)

Request Metadata from broker.

Parameters: allTopics - if true: request info about all topics in cluster, if false: only request info about locally known topics. onlyForTopic - only request info about this topic includeInternal - include internal topics prefixed with __ timeout - maximum response time before failing.

Declaration
public Task<Metadata> Metadata(bool allTopics = true, Topic onlyForTopic = null, bool includeInternal = false, TimeSpan timeout = null)
Parameters
Type Name Description
System.Boolean allTopics
Topic onlyForTopic
System.Boolean includeInternal
System.TimeSpan timeout
Returns
Type Description
Task<Metadata>

Events

OnStatistics

Declaration
public event EventHandler<string> OnStatistics